// package com.likou.written.baorong;
//
// import java.util.concurrent.ArrayBlockingQueue;
// import java.util.concurrent.BlockingQueue;
//
// /**
//  * Author: 陈桂明
//  * Date: 2025/10/17 19:32
//  * Description: baorong1
//  */
// public class baorong1 {
//     class Producer implements Runnable {
//         private BlockingQueue<Integer> queue;
//
//         public Producer(BlockingQueue<Integer> queue) {
//             this.queue = queue;
//         }
//
//
//         @Override
//         public void run() {
//             try {
//                 for (int i = 1; i <= 20; i++) {
//                     System.out.println("生产者存入元素：" + i);
//                     queue.put(i);
//                     Thread.sleep(500);
//                 }
//             } catch (InterruptedException e) {
//                 e.printStackTrace();
//             }
//         }
//     }
//
//     class Consumer implements Runnable {
//         private BlockingQueue<Integer> queue;
//
//         public Consumer(BlockingQueue<Integer> queue) {
//             this.queue = queue;
//         }
//
//
//         @Override
//         public void run() {
//             try {
//                 while (true) {
//                     Integer value = queue.take();
//                     System.out.println("消费者取出元素：" + value);
//                     Thread.sleep(800);
//                 }
//             } catch (InterruptedException e) {
//                 e.printStackTrace();
//             }
//         }
//     }
//
//     public class BlockingQuereDemo {
//         public static void main(String[] args) {
//             BlockingQueue<Integer> queue = new ArrayBlockingQueue<>(10);
//             Producer producer = new Producer(queue);
//             Consumer consumer = new Consumer(queue);
//             new Thread(producer).start();
//             new Thread(consumer).start();
//         }
//     }
// }
